Page({
  data: {
    tcpSocket: null,      // TCP Socket 对象
    status: "未连接",      // 连接状态
    inputText: "",         // 用户输入的字符串
    serverResponse: ""     // 服务器返回的内容
  },

  // 连接服务器
  connectToServer() {
    const tcp = wx.createTCPSocket();
    this.setData({ tcpSocket: tcp });

    tcp.connect({address: 'hhh88.tech',port: 8889,});

    // 监听服务器返回的数据
    tcp.onMessage((res) => {
      console.log('收到服务器数据:', res.message);
      const message = new TextDecoder().decode(res.message);
      this.setData({ serverResponse: message });
    });

    tcp.onConnect(() => {
      console.log('onConnect 触发');
      this.setData({ status: '已连接' });
    });

    tcp.onClose(() => {
      console.log('连接已关闭');
      this.setData({ status: '已断开' });
    });

    tcp.onError((err) => {
      console.error('TCP 错误:', err);
      this.setData({ status: '错误: ' + err.errMsg });
    });
  },

  // 断开连接
  disconnectFromServer() {
    const { tcpSocket } = this.data;
    if (tcpSocket) {
      tcpSocket.close();
    }
    this.setData({ status: '已断开' });
  },

  // 监听用户输入
  onInputChange(e) {
    this.setData({ inputText: e.detail.value });
  },

  // 发送数据到服务器
  sendToServer() {
    const { tcpSocket, inputText } = this.data;
    if (!tcpSocket) {
      wx.showToast({ title: '请先连接服务器', icon: 'none' });
      return;
    }
    if (!inputText.trim()) {
      wx.showToast({ title: '请输入内容', icon: 'none' });
      return;
    }
    tcpSocket.write(inputText); 
  }


});